package com.xzmzhp.dao.activity.SQL;

import com.xzmzhp.utils.StringUtils;
import org.apache.ibatis.jdbc.SQL;

/**
 * @author: 王源(xm)
 * @create: 2022-04-03 09:16
 * @program: ams
 * @description: 活动人员sql
 */
public class ActivityPersonnelSql {

    /**
     * 批量添加活动人员信息
     * @param activityId 活动id
     * @param personnelId 人员id集合
     * @return sql
     */
    public String addActivityPersonnel(Integer activityId,Integer[] personnelId){
        return new SQL(){
            {
                INSERT_INTO("activity_personnel");
                for (Integer i : personnelId) {
                    VALUES("activity_personnel_id",null);
                    VALUES("activity_id",activityId.toString());
                    VALUES("personnel_id",i.toString());
                }
            }
        }.toString();
    }

    /**
     * 删除活动人员信息
     * @param activityId 活动id
     * @param personnelId 活动人员id集合
     * @return 是否成功
     */
    public String delActivityPersonnel(Integer activityId,Integer[] personnelId){
        return new SQL(){
            {
                DELETE_FROM("activity_personnel");
                WHERE("activity_id = "+activityId);
                WHERE("personnel_id in ("+ StringUtils.convert(personnelId) +")");
            }
        }.toString();
    }

}
